def get_mission_kafka_key_dict(mission, data):
    if mission not in kafka_key_dict:
        return None
    key_func = kafka_key_dict[mission]
    return key_func(mission, data)


kafka_key_dict = {
    'auto_delete_false_qtime': lambda mission, data: mission + ":" + str(data['EQPID']),
}
